package com.gitee.xhs.customFunction;

import com.gitee.xhs.dao.IterateTransaction;
import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.streaming.api.functions.co.CoMapFunction;

/**
 * @author BigHead
 * @date 2022/7/20 10:40
 * @description OperatorCoMap
 */
public class OperatorCoMap implements CoMapFunction<Transaction, IterateTransaction, Transaction> {

    @Override
    public Transaction map1(Transaction value) throws Exception {
        return value;
    }

    @Override
    public Transaction map2(IterateTransaction value) throws Exception {
        return value.getTransaction();
    }

}
